from pyspark.sql import SparkSession

if __name__ == "__main__":
    #
    spark = SparkSession.builder.appName("PySql").getOrCreate()

    spark.sparkContext.setLogLevel("ERROR")
    df = spark.read.csv("../data/attribute.csv", header=True, inferSchema=True)
    df.printSchema()